package rabbitmq.constant;

/**
 * 基本使用类
 */

public class Constants {
    public static final String HOST = "8.147.235.141"; // 设置IP
    public static final Integer PORT = 5672; // 设置开放的端口号，需要提前开放
    public static final String USER_NAME = "admin"; // 设置RabbitMQ 的账号
    public static final String PASSWORD = "h2715711919.s"; // 设置RabbitMQ 的密码
    public static final String VIRTUAL_HOST = "study";  // 设置 虚拟主机

    // 工作队列模式
    public static final String WORK_QUEUE = "work.queue";

    // 发布订阅模式
    public static final String FANOUT_EXCHANGE = "fanout.exchange";
    public static final String FANOUT_QUEUE1 = "fanout.queue1";
    public static final String FANOUT_QUEUE2 = "fanout.queue2";

    // 路由模式
    public static final String  DIRECT_EXCHANGE = "direct.exchange";
    public static final String  DIRECT_QUEUE1 = "direct.queue1";
    public static final String  DIRECT_QUEUE2 = "direct.queue2";

    // 通配符模式
    public static final String  TOPIC_EXCHANGE = "topic.exchange";
    public static final String  TOPIC_QUEUE1 = "topic.queue1";
    public static final String  TOPIC_QUEUE2 = "topic.queue2";

    // RPC模式
    public static final String RPC_REQUEST_QUEUE = "rpc.request.queue"; // 请求
    public static final String RPC_RESPONSE_QUEUE = "rpc.response.queue"; // 响应

    // publisher confirms
    public static final String PUBLISHER_CONFIRMS_QUEUE1 = "publisher.confirms.queue1";
    public static final String PUBLISHER_CONFIRMS_QUEUE2 = "publisher.confirms.queue2";
    public static final String PUBLISHER_CONFIRMS_QUEUE3 = "publisher.confirms.queue3";

    // 推拉模式测试
    public static final String MESSAGE_QUEUE = "message.queue";
}
